﻿using System;

namespace WJ.Infrastructure.CQRS
{
    public interface IMessageBus : IDisposable
    {
        bool Publish(IMessage message);


        void Subscribe(Action<IMessage> handle, string[] toPic, string routeKey);
    }
}